package com.shujia.common

import org.apache.spark.sql.SparkSession

object Test extends SparkTool {

  override def run(spark: SparkSession): Unit = {
    import spark.implicits._
    import org.apache.spark.sql.functions._

    println(day_id)
    // 写对应的处理逻辑
    println("run")
  }
}
